package kafka.loganalysis;

import kafka.KafkaProperties;
import kafka.utils.ZkUtils;

import java.util.Properties;

/**
 * @author: pizhihui
 * @datae: 2017-11-08
 */
public class AppMain {

    public static void main(String[] args) {

        Properties props = new Properties();
        props.put("bootstrap.servers", KafkaProperties.BROKER_CONNECT);
        props.put("acks", "all");
        props.put("retries", 0);
        props.put("batch.size", 16384);
        props.put("linger.ms", 1);
        props.put("buffer.memory", 33554432);
        //props.put("partitioner.class", "com.cuicui.kafkademon.javaclient.JPartitioner");
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");





    }

}
